package com.chis.flink;

import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

public class MysqlTestImpl implements IMysqlTest{
    @Override
    public void inserTest(FlinkTestBean bean) {
        System.out.println("=======inserTest======");
    }

    @Override
    public List<FlinkTestBean> findTest() {
        FlinkTestBean flinkTestBean = new FlinkTestBean();
        flinkTestBean.setS1("wlj");
        flinkTestBean.setS2("fyy");
        List<FlinkTestBean> list = new ArrayList<>();
        list.add(flinkTestBean);
        return list;
    }
}
